package cn.kaiux.bigdata.homework.week07_08

import org.apache.spark.sql.SparkSessionExtensions

/**
 * @author kaiux@foxmail.com
 * @date 2022/6/25 15:58
 */
class MySparkSessionExtension extends (SparkSessionExtensions => Unit) {
  override def apply(extensions: SparkSessionExtensions): Unit = {
    extensions.injectOptimizerRule { session =>
      MyPushDown(session)
    }
  }
}

